package com.atguigu.flink.function;

import com.atguigu.flink.bean.WaterSensor;
import org.apache.flink.api.java.functions.KeySelector;

public class WaterSensorKeySelector implements KeySelector<WaterSensor , String> {
    @Override
    public String getKey(WaterSensor ws) throws Exception {
        return ws.id;
    }
}
